package com.primi.chen;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class StreamingJob {

	public static void main(String[] args) throws Exception {
		final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

		DataStream<String> stream = env.fromElements("TEST");
		stream.map(v->v.concat("001")).print();
		stream.map(v->v.concat("002")).print();
		stream.map(v->v.concat("003")).print();
		stream.map(v->v.concat("004")).print();

		env.execute("Flink Streaming Java API Skeleton");
	}
}
